package com.lx.onbording.vshe.osgistarter.consumer;

import java.util.Timer;

import com.lx.onbording.vshe.osgistarter.producer.api.RequestResponseService;

public class SimpleResponseConsumer {
	private RequestResponseService requestResponseService;

	public void init() {
		Timer timer = new Timer();
		// Start the task with a fixed delay of 5000 ms after 500 ms.
		timer.scheduleAtFixedRate(new ConsoleResponder(requestResponseService),
				500l, 5000l);
	}

	public void setRequestResponseService(
			RequestResponseService requestResponseService) {
		this.requestResponseService = requestResponseService;
	}

}
